package com.atguigu.flink.source;

import org.apache.flink.connector.kafka.source.KafkaSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

public class GetSourceFromKafka {

    public static void main(String[] args) {

        StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

        KafkaSource.builder()
                .setBootstrapServers("hadoop102:9092")
                .setTopics("first")
                .build();
    }
}
